package com.bluefox.config.thread;

import com.bluefox.utils.SpringContextHolder;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @CLassName ThreadPoolExecutorUtil
 * @Description 用于获取自定义线程池  测试
 * @Author 孙峰
 * @Date 2020/1/1 14:42
 * @Version 1.0
 */
public class ThreadPoolExecutorUtil {
    public static ThreadPoolExecutor getPoll() {
        AsyncTaskProperties properties = SpringContextHolder.getBean(AsyncTaskProperties.class);
        //corePoolSize：表示线程池保有的最小线程数。
        return new ThreadPoolExecutor(properties.getCorePoolSize(),
                //表示线程池创建的最大线程数。
                properties.getMaxPoolSize(),
                properties.getKeepAliveSeconds(),
                TimeUnit.SECONDS,
                //workQueue：工作队列  只有ArrayBlockingQueue 和LinkedBlockingQueue 、LinkedBlockingDeque 支持有界的
                // ----------------注意是支持有界--------------------
                new ArrayBlockingQueue<>(properties.getQueueCapacity()),
                // 给线程起个优雅的名字
                new TheadFactoryName(),
                // 拒绝策略  有四种
                // CallerRunsPolicy：提交任务的线程自己去执行该任务。
                // AbortPolicy：默认的拒绝策略，会 throws RejectedExecutionException。
                // DiscardPolicy：直接丢弃任务，没有任何异常抛出。
                // DiscardOldestPolicy：丢弃最老的任务，其实就是把最早进入工作队列的任务丢弃，然后把新任务加入到工作队列。

                new ThreadPoolExecutor.CallerRunsPolicy());
    }
}
